import json
class PricescrapyPipeline:
    # 初始化方法，以写方式打开price.json文件
    def __init__(self):
        self.json_file = open("D:/scrapy/price.json", 'w')
 
    def process_item(self, item, spider):
        # spider 每yield一次，此函数就会执行一次；
        # item对象转为字典
        item = dict(item)
        # 将yield过来的数据写入到json文件，将数据序列化，进行换行
        price_json = json.dumps(item, ensure_ascii=False) + '\n'
        # 写入price.json文件内
        self.json_file.write(price_json)
        return item
 
    # 当对象将被删除前，关闭price.json文件
    def __del__(self):
        self.json_file.close()
